package com.atguigu.member.controll

import com.atguigu.member.service.AdsMemberService
import com.atguigu.util.{BaseControll, HiveUtil}
import org.apache.spark.sql.SparkSession

/**
 * description ：统计指标
 * author      ：剧情再美终是戏 
 * mail        : 13286520398@163.com
 * date        ：Created in 2020/3/6 15:32
 * modified By ：
 * version:    : 1.0
 */
object AdsMemberControll extends BaseControll {
  override def initAppName(appName: String) = super.initAppName(AdsMemberControll.getClass.getName)

  override def doSmething(spark: SparkSession, dt: String, dn: String) = {
    //开启动态分区
    HiveUtil.openDynamicPartition(spark)

    // 查询指标
    AdsMemberService.queryDetailBySql(spark, dt, dn) // 使用 spark sql查询
    AdsMemberService.queryDetailByApi(spark, dt, dn) // 使用 spark api 查询
  }
}
